# -*- coding: utf-8 -*-
from datetime import timedelta, datetime
from utils.operators.files_bash_operator import FilesBashOperator
from jms_hi.dm.dm_oms_order_mark_detail_hi import jms_hi__dm_oms_order_mark_detail_hi

jms_dm__distcp_dm_order_mark_hi = FilesBashOperator(
    task_id="jms_dm__distcp_dm_order_mark_hi",
    email=['guoruiling@jtexpress.com','yl_bigdata@yl-scm.com'],
    bash_command="jms_hi/dm/distcp_dm_order_mark_hi/execute.sh",
    # execution_timeout=max(datetime.now().replace(hour=7, minute=0, second=0) - datetime.now(), timedelta(seconds=1)),
    retries=0,
    pool='default_pool',
    pool_slots=1
)

jms_dm__distcp_dm_order_mark_hi << jms_hi__dm_oms_order_mark_detail_hi
